import logging

from apscheduler.schedulers.blocking import BlockingScheduler

# 创建一个调度器
scheduler = BlockingScheduler()


def cycle_job():
    try:
        logging.info(">>>>>>开仓start<<<<<<")

    except Exception as e:
        pass
        # db.close()


def main():
    scheduler.add_job(cycle_job, 'interval', seconds=10)
    scheduler.start()


if __name__ == '__main__':
    main()
